package com.thlws.study.redismq.context;

import lombok.Data;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.listener.Topic;

import java.io.Serializable;

/**
 * @author HanleyTang 2019-07-31
 */
@Data
public class RedisMessageChannel implements Serializable {

    private Topic topic;
    private MessageListener listener;

    public RedisMessageChannel(MessageListener listener, Topic topic) {
        this.listener = listener;
        this.topic = topic;
    }
}
